package com.atguigu.flink;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;

/**
 * 在此写计算逻辑，按行输入，每行有若干单词，用空格分隔
 * 返回(word, count)元组流
 */
public class Practice {
    public static SingleOutputStreamOperator<Tuple2<String, Long>> run(DataStreamSource<String> source) {
        return null;
    }
}
